package com.njbdqn.root

import com.njbdqn.call.{ALSCall, GlobalHotsellCall, GroupCall}
import com.njbdqn.datahandler.{KMeansDataHandler, LRDataHandler}
import com.njbdqn.filter.BanGoodFilter
import com.njbdqn.sort.LRGoodSort
import com.njbdqn.util.{HDFSConnection, MySQLConnection, ReadPropertiesFileTool}
import org.apache.spark.sql.SparkSession

object App {
  def main(args: Array[String]): Unit = {
   val spark = SparkSession.builder().master("local[*]").appName("commend").getOrCreate()
    //调用过滤模块先过滤掉不能推荐的商品
    //BanGoodFilter.ban(spark)
    //调用召回模块完成任务
      //1.全局热卖召回
      //GlobalHotsellCall.hotSell(spark)
      //2.分组召回
      //GroupCall.call(spark)
      //3.ALS召回
      //ALSCall.call(spark)
    //调用LRDataHandler并使用NotGoodFilter过滤掉用户已经购买的商品
    LRGoodSort.grade(spark)
    //调用排序模块
   spark.stop()
  }
}
